package com._1.message;

import com._1.message.kafka.KafkaProducerService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;


@SpringBootTest
public class KafkaTestRunner {

    @Autowired
    private KafkaProducerService kafkaProducerService;

    @Test
    public void testKafka() throws InterruptedException {
        kafkaProducerService.sendMessage("broadcast_topic", "test12");
        Thread.sleep(10000);
    }
}
